package com.ma.implatform.service.impl;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ma.common.utils.ThreadPoolExecutorFactory;
import com.ma.implatform.dto.GroupMessageDTO;
import com.ma.implatform.entity.GroupMessage;
import com.ma.implatform.mapper.GroupMessageMapper;
import com.ma.implatform.service.GroupMessageService;
import com.ma.implatform.session.SessionContext;
import com.ma.implatform.session.UserSession;
import com.ma.implatform.vo.GroupMessageVO;

import java.util.List;
import java.util.concurrent.ScheduledThreadPoolExecutor;

public class GroupMessageServiceImpl extends ServiceImpl<GroupMessageMapper, GroupMessage> implements GroupMessageService  {

    private static final ScheduledThreadPoolExecutor EXECUTOR = ThreadPoolExecutorFactory.getThreadPoolExecutor();
    @Override
    public GroupMessageVO sendMessage(GroupMessageDTO dto) {
        UserSession session = SessionContext.getSession();

        return null;
    }

    @Override
    public GroupMessageVO recallMessage(Long id) {

        return null;
    }

    @Override
    public void pullOfflineMessage(Long minId) {

    }

    @Override
    public List<GroupMessageVO> loadOfflineMessage(Long minId) {
        return null;
    }

    @Override
    public void readedMessage(Long groupId) {

    }

    @Override
    public List<Long> findReadedUsers(Long groupId, Long messageId) {
        return null;
    }

    @Override
    public List<GroupMessageVO> findHistoryMessage(Long groupId, Long page, Long size) {
        return null;
    }
}
